package org.learn.java.mq.localTransactionCheck;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.aliyun.openservices.ons.api.Message;
import com.aliyun.openservices.ons.api.transaction.LocalTransactionChecker;
import com.aliyun.openservices.ons.api.transaction.TransactionStatus;

public class MyLocalTransactionChecker implements LocalTransactionChecker {

	private static Logger logger = LoggerFactory.getLogger(MyLocalTransactionChecker.class);
	public TransactionStatus check(Message msg) {
		logger.debug("--MyLocalTransactionChecker.TransactionStatus--");
		logger.debug("----msgId:"+msg.getMsgID()+"--"+"topic:"+msg.getTopic()+"----");
		logger.debug("----hi,blue6! no response with business status,tell me why? I will check it!----");
		return null;
	}

	

}
